/* Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.mybatisx.mybatisplus.activiti.rest.editor;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.node.ObjectNode;
import org.activiti.editor.constants.ModelDataJsonConstants;
import org.activiti.engine.ActivitiException;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Model;
import org.apache.batik.transcoder.TranscoderInput;
import org.apache.batik.transcoder.TranscoderOutput;
import org.apache.batik.transcoder.image.PNGTranscoder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;

/**
 * @author Tijs Rademakers
 */
@RestController
@RequestMapping("/service")
public class ModelSaveRestResource implements ModelDataJsonConstants {

  protected static final Logger LOGGER = LoggerFactory.getLogger(ModelSaveRestResource.class);

  @Autowired
  private RepositoryService repositoryService;

  @Autowired
  private ObjectMapper objectMapper;

  @RequestMapping(value="/model/{modelId}/save",  method = {RequestMethod.POST, RequestMethod.PUT})
  @ResponseStatus(value = HttpStatus.OK)
  public void saveModel(@PathVariable String modelId
          , String name, String description
          , String json_xml, String svg_xml, HttpServletRequest request) {
    try {
      Model model = repositoryService.getModel(modelId);

      ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo());

      modelJson.put(MODEL_NAME, name);
      modelJson.put(MODEL_DESCRIPTION, description);
      model.setMetaInfo(modelJson.toString());
      model.setName(name);

     /* //获取所有引擎
      Map<String,ProcessEngine> engines = ProcessEngines.getProcessEngines();
      // 1:得到ProcessEngine对象
      ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
      // 2:获取RuntimeService服务
   	  RuntimeService runtimeService = engine.getRuntimeService();

   	  // 3:根据KEY启动流程实例
      ProcessInstance holiday = runtimeService.startProcessInstanceByKey("入库单");
      //ProcessInstance holiday1 = runtimeService.startProcessInstanceById("入库单");
      // 4:输出信息
      System.out.println("流程定义ID:" + holiday.getProcessDefinitionId());
      System.out.println("流程实例ID:" + holiday.getId());//15211
      System.out.println("当前活跃ID:" + holiday.getActivityId());
      TaskService taskService = engine.getTaskService();
      List<Task> tasks = taskService.createTaskQuery().processInstanceId("15211").list();
      for (Task task : tasks) {
    	  Execution exe = runtimeService.createExecutionQuery().executionId(task.getExecutionId()).singleResult();
    	  taskService.complete(task.getId());
      }*/
//      List<ProcessDefinition> list = engine.getRepositoryService().createProcessDefinitionQuery().list();
//      for(ProcessDefinition pd : list){
//    	  System.out.println(pd.getId());
//    	  System.out.println(pd.getDeploymentId());
//      }
      /*TaskService taskService = engine.getTaskService();
      //查询全部的任务，得到相应的执行流，设置不同的参数
      List<Task> tasks = taskService.createTaskQuery().processInstanceId(holiday.getId()).list();
      //两个执行流时输出参数
      for (Task task : tasks) {
    	  Execution exe = runtimeService.createExecutionQuery().executionId(task.getExecutionId()).singleResult();
    	  taskService.complete(task.getId());
      }*/

      /*ProcessDefinitionEntity processDefinitionEntity = (ProcessDefinitionEntity) ((RepositoryServiceImpl) repositoryService)
              .getDeployedProcessDefinition("15125");  */
      //遍历所有节点信息
      /*for(ActivityImpl activityImpl : activitiList){
          id = activityImpl.getId();
          if (activitiId.equals(id)) {
              //获取下一个节点信息
              task = nextTaskDefinition(activityImpl, activityImpl.getId(), null, processInstanceId);
              break;
          }
      } */

      //List<Execution> exes =runtimeService.createExecutionQuery().activityId("sid-BCFF614E-C11C-4B72-ABD4-A454114D2BA4").list();
      repositoryService.saveModel(model);

      repositoryService.addModelEditorSource(model.getId(), json_xml.getBytes("utf-8"));

      InputStream svgStream = new ByteArrayInputStream(svg_xml.getBytes("utf-8"));
      TranscoderInput input = new TranscoderInput(svgStream);

      PNGTranscoder transcoder = new PNGTranscoder();
      // Setup output
      ByteArrayOutputStream outStream = new ByteArrayOutputStream();
      TranscoderOutput output = new TranscoderOutput(outStream);

      // Do the transformation
      transcoder.transcode(input, output);
      final byte[] result = outStream.toByteArray();
      repositoryService.addModelEditorSourceExtra(model.getId(), result);
      outStream.close();

    } catch (Exception e) {
      LOGGER.error("Error saving model", e);
      throw new ActivitiException("Error saving model", e);
    }
  }
}
